package com.lxw.mq;


import com.lxw.MqConst;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@SpringBootTest
@RunWith(SpringRunner.class)
@Slf4j
public class MqTest {




    @Autowired
    RabbitTemplate rabbitTemplate;

    @Test
    public void send1(){
       //work队列工作模式 发送到默认的交换机
        rabbitTemplate.convertAndSend(MqConst.TEST_QUEUE,"你好 work工作模式");

    }
    @Test
    public void send2(){
        //订阅模式
        rabbitTemplate.convertAndSend(MqConst.EXCHANGE_FANOUT,"","你好 订阅工作模式 1队列");

    }

    @Test
    public void send3(){
        //路由模式
        rabbitTemplate.convertAndSend(MqConst.EXCHANGE_DIRECT,"info","这是一个路由信息");

    }
    @Test
    public void send4(){
        //路由模式
        rabbitTemplate.convertAndSend(MqConst.EXCHANGE_DIRECT,"warn","这是一个路由warn信息");

    }
    //topic 模式

    @Test
    public void send5(){
        //路由模式
        rabbitTemplate.convertAndSend(MqConst.EXCHANGE_TOPIC,MqConst.TOPIC_INFO,"这是一个Topic信息");

    }

    //router测试 模式

    @Test
    public void send6(){
        //路由模式
        rabbitTemplate.convertAndSend("ex_routing_cms_postpage","5a751fab6abb5044e0d19ea1","这是一个Topic信息");

    }

}
